home
***
CD-ROM
|
disk
|
FTP
|
other
***
search
/
NeXTSTEP 3.3 (Developer)…68k, x86, SPARC, PA-RISC]
/
NeXTSTEP 3.3 Dev Intel.iso
/
usr
/
sybase
/
sample
/
dblibrary
/
example2.c
< prev
next >
Wrap
C/C++ Source or Header
|
1993-04-22
|
5KB
|
211 lines
/*
** example2.c
**
** This example opens a data file, inserts data from the file
** into a newly created table containing several of the
** SQL Server datatypes, and binds and prints the results.
*/
#include <stdio.h>
#include <sybfront.h>
#include <sybdb.h>
#define BUFLEN 2048
#define HEXLEN 510
#define PLEN 25
/* Forward declarations of the error handler and message handler routines. */
int err_handler();
int msg_handler();
main(argc,argv)
int argc;
char *argv[];
{
LOGINREC *login;
DBPROCESS *dbproc;
RETCODE return_code;
DBTINYINT age;
DBSMALLINT userid;
DBINT royalty;
DBCHAR name[PLEN+1];
DBBINARY title_id[PLEN+1];
DBBIT us_citizen;
DBFLT8 account;
DBCHAR title[PLEN+1]; /* string */
DBCHAR manager[PLEN+1]; /* ntbstring */
DBCHAR id_buffer[HEXLEN+1];
char cmdbuf[BUFLEN];
FILE *infile;
/* Initialize DB-Library. */
if (dbinit() == FAIL)
exit(ERREXIT);
/* Install the user-supplied error-handling and message-handling
* routines. They are defined at the bottom of this source file.
*/
dberrhandle(err_handler);
dbmsghandle(msg_handler);
/* Allocate and initialize the LOGINREC structure to be used
* to open a connection to SQL Server.
*/
login = dblogin();
DBSETLPWD(login, "server_password");
DBSETLAPP(login, "example2");
dbproc = dbopen(login, NULL);
printf("Creating the 'test' database.\n");
dbcmd(dbproc,"create database test ");
dbsqlexec(dbproc);
dbuse(dbproc,"test");
printf("Creating the 'alltypes' table.\n");
/* Create a table that contains several SQL Server datatypes. */
dbcmd(dbproc,"create table alltypes ");
dbcmd(dbproc,"(age tinyint,");
dbcmd(dbproc,"userid smallint,");
dbcmd(dbproc,"royalty int,");
dbcmd(dbproc,"name char(25),");
dbcmd(dbproc,"title_id varbinary(20),");
dbcmd(dbproc,"us_citizen bit,");
dbcmd(dbproc,"account float,");
dbcmd(dbproc,"title varchar(20),");
dbcmd(dbproc,"manager char(25))");
dbsqlexec(dbproc);
/* Insert rows of data into the newly created table "alltypes".
* We will read in the contents of the file and form an
* INSERT statement.
*/
if ((infile=fopen("datafile","r")) == NULL)
{
printf("Unable to open file 'datafile'.\n");
exit(STDEXIT);
}
printf("Inserting rows into the 'alltypes' table.\n");
while ((fgets(cmdbuf,BUFLEN,infile)) != NULL)
{
dbfcmd(dbproc,"insert into alltypes \n");
dbfcmd(dbproc,"values(%s) \n",cmdbuf);
}
dbsqlexec(dbproc);
/* Process the results of each of the INSERT statements. */
while ((return_code = dbresults(dbproc)) != NO_MORE_RESULTS)
{
if (return_code == FAIL)
printf("One of the insert statements FAILed.\n");
}
printf("Selecting rows from the 'alltypes' table:\n");
dbcmd(dbproc,"select * from alltypes");
dbsqlexec(dbproc);
while ((return_code = dbresults(dbproc)) != NO_MORE_RESULTS)
{
if (return_code == SUCCEED)
{
dbbind(dbproc, 1, TINYBIND, (DBINT)0, (BYTE *)&age);
dbbind(dbproc, 2, SMALLBIND, (DBINT)0, (BYTE *)&userid);
dbbind(dbproc, 3, INTBIND, (DBINT)0, (BYTE *)&royalty);
dbbind(dbproc, 4, CHARBIND, (DBINT)0, name);
dbbind(dbproc, 5, BINARYBIND, (DBINT)0, title_id);
dbbind(dbproc, 6, BITBIND, (DBINT)0, (BYTE *)&us_citizen);
dbbind(dbproc, 7, FLT8BIND, (DBINT)0, (BYTE *)&account);
dbbind(dbproc, 8, STRINGBIND, (DBINT)0, title);
dbbind(dbproc, 9, NTBSTRINGBIND, (DBINT)0, manager);
/*
** Initialize null terminator in "name" array,
** since CHARBIND does not add one.
*/
name[PLEN] = '\0';
while (dbnextrow(dbproc) != NO_MORE_ROWS)
{
dbconvert
(dbproc, SYBBINARY, title_id,
dbdatlen(dbproc, 5), SYBCHAR, id_buffer, (DBINT)-1);
printf
("%d %d %ld %s 0x%s\n",
age, userid, royalty, name, id_buffer);
printf
("%d %8.2f %s %s\n",
us_citizen, account, title, manager);
}
}
}
dbexit();
exit(STDEXIT);
}
int err_handler(dbproc, severity, dberr, oserr, dberrstr, oserrstr)
DBPROCESS *dbproc;
int severity;
int dberr;
int oserr;
char *dberrstr;
char *oserrstr;
{
if ((dbproc == NULL) || (DBDEAD(dbproc)))
return(INT_EXIT);
else
{
printf("DB-Library error:\n\t%s\n", dberrstr);
if (oserr != DBNOERR)
printf("Operating-system error:\n\t%s\n", oserrstr);
return(INT_CANCEL);
}
}
int msg_handler(dbproc, msgno, msgstate, severity, msgtext,
srvname, procname, line)
DBPROCESS *dbproc;
DBINT msgno;
int msgstate;
int severity;
char *msgtext;
char *srvname;
char *procname;
DBUSMALLINT line;
{
printf ("Msg %ld, Level %d, State %d\n",
msgno, severity, msgstate);
if (strlen(srvname) > 0)
printf ("Server '%s', ", srvname);
if (strlen(procname) > 0)
printf ("Procedure '%s', ", procname);
if (line > 0)
printf ("Line %d", line);
printf("\n\t%s\n", msgtext);
return(0);
}